package consumer

func init() {

}

//func BalanceConsumer(ctx context.Context, queuename, consumer string) {
//	upstreams := config.ServiceConfig.Upstreams
//	for k, v := range upstreams {
//		go amqp.Consumer(context.Background(), k, v)
//	}
//}
